package org.example.handler;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import lombok.extern.slf4j.Slf4j;
import org.example.domain.po.PingMessagePO;

/**
 * 心跳检测处理器
 *
 * @author chenlei
 */
@Slf4j
public class PingMessageHandler extends SimpleChannelInboundHandler<PingMessagePO> {

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, PingMessagePO msg) throws Exception {
        log.debug("接收到心跳信号{}", msg);

    }

}
